/* thread.c
 * 
 *  POSIX thread API wrapper
 */
 
#include <librally.h>

Err rp_mutext_init(rp_mutex_t *mutex)
{
	return E_OK;
}

Err rp_mutex_destory(rp_mutex_t *mutex)
{
	return E_OK;
}

Err rp_mutex_lock(rp_mutex_t *mutex)
{
	return E_OK;
}

Err rp_mutex_unlock(rp_mutex_t *mutex)
{
	return E_OK;
}

Err rp_thread_create(rp_thread_t *tid, ThreadFunc func, void *argv)
{
	return E_OK;
}

Err rp_thread_cancel(rp_thread_t tid)
{
	return E_OK;
}

Err rp_thread_join(rp_thread_t tid, void  **status)
{
	return E_OK;
}

void rp_thread_exit(void *status)
{
        return;
}

Err rp_thread_run(rp_mutex_t *mutex)
{
	return E_OK;
}

Err rp_threadpool_init(int count, rp_thread_t *tid, ThreadFunc func, void *arg[])
{
	return E_OK;
}

Err rp_threadpool_new(rp_thread_t *tid_old[], ThreadFunc func, void *arg)
{
	return E_OK;
}

Err rp_threadpool_del(int rank)
{
	return E_OK;
}

Err rp_threadpool_destroy()
{
	return E_OK;
}

Err rp_cqueue_init(Cqueue *cqueue, int qlength)
{
	return E_OK;
}

Err rp_cqueue_finalize(Cqueue *cqueue)
{
	return E_OK;
}

Err rp_cqueue_put(Cqueue *cqueue, Cmd *cmd)
{
	return E_OK;
}

Cmd *rp_cqueue_get(Cqueue *cqueue)
{
	return NULL;
}

Err rp_tqueue_init(Tqueue *tqueue, int qlength)
{
	return E_OK;
}

Err rp_tqueue_finalize(Tqueue *tqueue)
{
	return E_OK;
}

Err rp_tqueue_put(Tqueue *tqueue, Task *task)
{
	return E_OK;
}

Task *rp_tqueue_get(Tqueue *tqueue)
{
	return NULL;
}

